home
***
CD-ROM
|
disk
|
FTP
|
other
***
search
/
Workbench Add-On
/
Workbench Add-On - Volume 1.iso
/
BBS-Archive
/
Comm
/
term-source.lha
/
Extras
/
Source
/
term-Source.lha
/
termXPR.c
< prev
next >
Wrap
C/C++ Source or Header
|
1995-07-02
|
58KB
|
2,737 lines
/*
** termXPR.c
**
** External transfer protocol support routines
**
** Copyright © 1990-1995 by Olaf `Olsen' Barthel
** All Rights Reserved
*/
#include "termGlobal.h"
/* These variables keep the transferred bytes and transfer
* time in seconds.
*/
STATIC LONG ByteVal,
ByteMax,
TimeVal,
TimeMax,
LastTimeDif,
LastPercent;
/* Transfer statistics. */
STATIC ULONG CPS_Minimum,
CPS_Maximum,
CPS_Average,
CPS_Current,
CPS_Count,
CPS_Last;
LONG CPL_Min,
CPL_Avg,
CPL_Cur;
/* The name of the file being transmitted, in case the
* `override transfer path' feature is enabled.
*/
STATIC struct Buffer *CurrentFile;
/* Yet another flag, this one determines whether we already told
* the user that the file we are currently processing will fit
* on the destination device.
*/
STATIC BYTE Alerted,
DontWorry,
TypeChecked,
ErrorNotified,
CarrierMessage;
STATIC UBYTE __far RealName[MAX_FILENAME_LENGTH];
STATIC ULONG LastSeconds;
/* PrintBox(LONG Box,LONG Line,STRPTR String,...):
*
* Update the contents of a text box.
*/
STATIC VOID __stdargs
PrintBox(LONG Box,LONG Line,STRPTR String,...)
{
UBYTE LocalBuffer[256];
va_list VarArgs;
va_start(VarArgs,String);
VSPrintf(LocalBuffer,String,VarArgs);
va_end(VarArgs);
LT_SetAttributes(TransferHandle,Box,
LABX_Index, Line,
LABX_Text, LocalBuffer,
TAG_DONE);
}
/* OpenTransferWindow():
*
* Local routine to open the transfer window.
*/
STATIC BYTE
OpenTransferWindow(VOID)
{
/* Block window input. */
BlockWindows();
/* Try to open the transfer window panel. */
if(TransferPanel(LocaleString(MSG_TERMXPR_RECEIVE_FILES_TXT)))
{
/* Supply the log text. */
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_INITIATE_BINARY_DOWNLOAD_TXT));
/* Return success. */
return(TRUE);
}
else
{
/* Re-enable window input. */
ReleaseWindows();
/* Return failure. */
return(FALSE);
}
}
/* CheckAbort(BOOLEAN CheckCarrier):
*
* Check for transfer abort.
*/
STATIC LONG __regargs
CheckAbort(BOOLEAN CheckCarrier)
{
struct IntuiMessage *Message;
ULONG MsgClass,
MsgQualifier;
UWORD MsgCode;
struct Gadget *MsgGadget;
struct Window *MsgWindow;
LONG Result = 0;
/* No window available for output? */
if(!TransferWindow)
{
if(!OpenTransferWindow())
return(-1);
}
/* Are we to check the carrier status? */
if(CheckCarrier)
{
/* Return error if carrier is lost. */
if(GetSerialStatus() & CIAF_COMCD)
{
if(!CarrierMessage)
{
CarrierMessage = TRUE;
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT));
}
ObtainSemaphore(&OnlineSemaphore);
if(Online)
{
WasOnline = Online;
Online = FALSE;
}
ReleaseSemaphore(&OnlineSemaphore);
TransferError = TRUE;
return(-1);
}
}
/* Process all incoming messages. */
while(Message = (struct IntuiMessage *)GT_GetIMsg(TransferWindow -> UserPort))
{
MsgClass = Message -> Class;
MsgQualifier = Message -> Qualifier;
MsgCode = Message -> Code;
MsgGadget = (struct Gadget *)Message -> IAddress;
MsgWindow = Message -> IDCMPWindow;
GT_ReplyIMsg(Message);
if(MsgWindow == TransferWindow)
{
if(!Result)
{
LT_HandleInput(TransferHandle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget);
if(MsgClass == IDCMP_CLOSEWINDOW)
{
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_TRANSFER_ABORTED_TXT));
TransferAborted = TRUE;
Result = -1;
}
if(MsgClass == IDCMP_GADGETUP)
{
switch(MsgGadget -> GadgetID)
{
case GAD_TRANSFER_ABORT:
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_TRANSFER_ABORTED_TXT));
TransferAborted = TRUE;
Result = -1;
break;
case GAD_TRANSFER_SKIP:
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_FILE_SKIPPED_TXT));
Result = 1;
break;
case GAD_TRANSFER_ABORT_FILE:
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_FILE_ABORTED_TXT));
Result = 2;
break;
}
}
}
}
else
{
if(TransferPerfWindow)
{
struct RastPort *RPort = TransferPerfWindow -> RPort;
if(MsgClass == IDCMP_NEWSIZE)
{
SetAPen(RPort,DrawInfo -> dri_Pens[BACKGROUNDPEN]);
RectFill(RPort,TransferPerfWindow -> BorderLeft,TransferPerfWindow -> BorderTop,TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1),TransferPerfWindow -> Height - (TransferPerfWindow -> BorderBottom + 1));
CPL_Min = CPL_Avg = CPL_Cur = -1;
}
if(MsgClass == IDCMP_CLOSEWINDOW)
{
PutWindowInfo(WINDOW_PERF,TransferPerfWindow -> LeftEdge,TransferPerfWindow -> TopEdge,TransferPerfWindow -> Width,TransferPerfWindow -> Height);
CloseWindowSafely(TransferPerfWindow);
TransferPerfWindow = NULL;
}
}
}
}
return(Result);
}
/* NewFileName(STRPTR Source,STRPTR Buffer):
*
* Build a valid file and path name, including path
* substitution, etc.
*/
STATIC STRPTR __regargs
NewFileName(STRPTR Source,STRPTR Buffer)
{
if(Config -> TransferConfig -> OverridePath && !Uploading)
{
if(DownloadPath)
strcpy(Buffer,DownloadPath);
else
strcpy(Buffer,Config -> PathConfig -> BinaryDownloadPath);
if(!Buffer[0])
{
if(!GetCurrentDirName(Buffer,MAX_FILENAME_LENGTH))
Buffer[0] = 0;
}
if(Buffer[0])
{
if(AddPart(Buffer,FilePart(Source),MAX_FILENAME_LENGTH))
return(Buffer);
}
}
else
{
if(FilePart(Source) == Source)
{
if(GetCurrentDirName(Buffer,MAX_FILENAME_LENGTH))
{
if(AddPart(Buffer,Source,MAX_FILENAME_LENGTH))
return(Buffer);
}
}
}
strcpy(Buffer,Source);
return(Source);
}
/* IdentifySource(STRPTR Name,STRPTR BBSName,struct DateStamp *OpenDate):
*
* Attach source information (BBS name, date and time) to a file.
*/
STATIC VOID __regargs
IdentifySource(STRPTR Name,STRPTR BBSName,struct DateStamp *OpenDate)
{
UBYTE LocalBuffer[MAX_FILENAME_LENGTH],
Time[40],
Date[40];
struct DateTime DateTime;
CopyMem(OpenDate,&DateTime . dat_Stamp,sizeof(struct DateStamp));
/* Prepare for date conversion. */
DateTime . dat_Format = FORMAT_DOS;
DateTime . dat_Flags = 0;
DateTime . dat_StrDay = NULL;
DateTime . dat_StrDate = Date;
DateTime . dat_StrTime = Time;
/* Convert the date. */
if(DateToStr(&DateTime))
{
StripSpaces(BBSName);
StripSpaces(Date);
StripSpaces(Time);
if(BBSName[0])
SPrintf(LocalBuffer,"%s %s %s",BBSName,Date,Time);
else
SPrintf(LocalBuffer,"%s %s",Date,Time);
SetComment(Name,LocalBuffer);
}
}
/* GetSeconds(STRPTR String):
*
* Tries to turn a string of the format hh:mm:ss into
* an integer number.
*/
STATIC LONG __regargs
GetSeconds(STRPTR String)
{
UBYTE Buffer[20];
LONG Seconds = 0;
memset(Buffer,0,20);
strcpy(Buffer,String);
Seconds += Atol(&Buffer[6]);
Buffer[5] = 0;
Seconds += Atol(&Buffer[3]) * 60;
Buffer[2] = 0;
Seconds += Atol(&Buffer[0]) * 3600;
return(Seconds);
}
/* TruncateName(STRPTR FileName):
*
* Truncates a file name to a maximum of 48 characters.
*/
STATIC STRPTR __regargs
TruncateName(STRPTR FileName)
{
WORD Len = strlen(FileName);
if(Len > 48)
{
WORD i;
for(i = Len - 48 ; i < Len ; i++)
{
if(i >= Len - 44 && FileName[i] == '/')
{
STATIC UBYTE __far NameBuffer[MAX_FILENAME_LENGTH];
strcpy(NameBuffer,".../");
strcat(NameBuffer,&FileName[i + 1]);
return(NameBuffer);
}
}
}
return(FileName);
}
/* IsBlockMappedDevice(struct MsgPort *Handler):
*
* See if the lock given points to a block mapped filing
* system.
*/
STATIC BOOL __regargs
IsBlockMappedDevice(struct MsgPort *Handler)
{
struct DosList *Entry;
BOOL IsBlockMapped = FALSE;
// Find the device the lock belongs to
if(Entry = LockDosList(LDF_DEVICES | LDF_READ))
{
while(Entry = NextDosEntry(Entry,LDF_DEVICES))
{
if(Entry -> dol_Task == Handler)
{
struct FileSysStartupMsg *Startup = (struct FileSysStartupMsg *)BADDR(Entry -> dol_misc . dol_handler . dol_Startup);
// Plain filing system usually don't
// use the startup entry
if(TypeOfMem(Startup))
{
STRPTR Name = (STRPTR)BADDR(Startup -> fssm_Device);
struct DosEnvec *Environ = (struct DosEnvec *)BADDR(Startup -> fssm_Environ);
// Valid data in the startup entry?
if(TypeOfMem(Name) && TypeOfMem(Environ))
{
struct IOStdReq __aligned Request;
memset(&Request,0,sizeof(struct IOStdReq));
// Last chance, try to open the device driver
if(!OpenDevice(Name + 1,Startup -> fssm_Unit,&Request,Startup -> fssm_Flags))
{
// This is a block mapped filing system
IsBlockMapped = TRUE;
CloseDevice(&Request);
break;
}
}
}
}
}
UnLockDosList(LDF_DEVICES | LDF_READ);
}
return(IsBlockMapped);
}
/* CalculateBlocks(LONG Size,LONG BlockSize):
*
* Calculate the number of blocks a file will
* occupy if saved to a disk.
*/
STATIC LONG __regargs
CalculateBlocks(LONG Size,LONG BlockSize)
{
LONG Blocks = 1; /* One for the file header. */
BYTE HasExtension = FALSE, /* No extension block yet. */
Extension = 0; /* How many block pointers yet. */
/* Round to next block. */
Size = ((Size + BlockSize - 1) / BlockSize) * BlockSize;
while(Size)
{
/* Add another block. */
Blocks++;
/* Subtract another block. */
Size -= BlockSize;
/* Add another block pointer, if 72 have been
* added, add another extension block.
*/
if((Extension++) == 72)
{
/* If no extension block has been generated
* yet, we were running on the block pointers
* of the file header itself.
*/
if(!HasExtension)
HasExtension = TRUE;
else
Blocks++;
/* Reset extension block counter. */
Extension = 0;
}
}
return(Blocks);
}
/* GetOptionMode(struct xpr_option *Option):
*
* Turn text into a boolean value.
*/
STATIC BYTE __regargs
GetOptionMode(struct xpr_option *Option)
{
if(Option)
{
STATIC STRPTR TrueOptions[] =
{
"ON",
"TRUE",
"T",
"YES",
"Y",
NULL
};
register WORD i;
for(i = 0 ; TrueOptions[i] ; i++)
{
if(!Stricmp(Option -> xpro_value,TrueOptions[i]))
return(TRUE);
}
}
return(FALSE);
}
/* SerialErrorReport(struct IOExtSer *Request):
*
* Report a certain I/O error cause.
*/
STATIC BYTE __regargs
SerialErrorReport(struct IOExtSer *Request)
{
STRPTR ErrorMessage;
BYTE IsFatal;
switch(Request -> IOSer . io_Error)
{
case SerErr_LineErr:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_HARDWARE_DATA_OVERRUN_TXT);
IsFatal = FALSE;
break;
case SerErr_ParityErr:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_PARITY_ERROR_TXT);
IsFatal = TRUE;
break;
case SerErr_TimerErr:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_TIMER_ERROR_TXT);
IsFatal = FALSE;
break;
case SerErr_BufOverflow:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_READ_BUFFER_OVERFLOWED_TXT);
IsFatal = FALSE;
break;
case SerErr_NoDSR:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_NO_DSR_TXT);
IsFatal = TRUE;
break;
case SerErr_DetectedBreak:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_BREAK_DETECTED_TXT);
IsFatal = TRUE;
break;
default:
ErrorMessage = LocaleString(MSG_TERMXPR_ERROR_UNKNOWN_CAUSE_TXT);
IsFatal = FALSE;
break;
}
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_ERROR_TEMPLATE_TXT),Request -> IOSer . io_Error,ErrorMessage);
if(IsFatal)
{
TransferError = TRUE;
return(TRUE);
}
else
return(FALSE);
}
/* xpr_fopen(STRPTR FileName,STRPTR AccessMode):
*
* Open a file for random access.
*/
LONG __saveds __asm
xpr_fopen(register __a0 STRPTR FileName,register __a1 STRPTR AccessMode)
{
UBYTE RealName[MAX_FILENAME_LENGTH];
struct Buffer *File;
DB(kprintf("xpr_fopen(\"%s\",\"%s\")\n",FileName,AccessMode));
Alerted = CarrierMessage = ErrorNotified = DontWorry = TypeChecked = FALSE;
/* Reset transfer counters. */
ByteVal = ByteMax = TimeVal = TimeMax = LastTimeDif = 0;
LastPercent = -1;
/* Reset CPS statistics. */
CPS_Minimum = (ULONG)~0;
CPS_Maximum = 0;
CPS_Average = 0;
CPS_Current = 0;
CPS_Count = 0;
CPS_Last = 0;
/* No window available for output? */
if(!TransferWindow)
OpenTransferWindow();
if(OriginalName[0])
{
if(!Stricmp(ShrunkenName,FileName))
FileName = OriginalName;
}
/* Determine the file name. */
FileName = NewFileName(FileName,RealName);
/* Determine file transfer mode... */
if(File = BufferOpen(FileName,AccessMode))
{
switch(AccessMode[0])
{
case 'r':
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_SEND_FILE_TXT),FileName);
break;
case 'w':
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_RECEIVE_FILE_TXT),FileName);
break;
case 'a':
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_UPDATE_FILE_TXT),FileName);
break;
}
CurrentFile = File;
}
DidTransfer = TRUE;
return((LONG)File);
}
/* xpr_fclose(struct Buffer *File):
*
* Close a file opened by xpr_fopen.
*/
LONG __saveds __asm
xpr_fclose(register __a0 struct Buffer *File)
{
UBYTE RealName[MAX_FILENAME_LENGTH];
struct DateStamp OpenDate;
BYTE WriteAccess,
Used;
DB(kprintf("xpr_fclose(0x%08lx)\n",File));
/* This happened only once so far, but... */
if(!File)
{
CurrentFile = NULL;
return(1);
}
/* Save some information. */
OpenDate = File -> OpenDate;
WriteAccess = File -> WriteAccess;
Used = File -> Used;
/* Get the name of the file. */
if(!NameFromFH(File -> FileHandle,RealName,MAX_FILENAME_LENGTH))
RealName[0] = 0;
/* Close the file and see what it brings... */
if(BufferClose(File) && RealName[0])
{
/* Did any access take place at all?
* xprzmodem.library for example just
* opens and closes a file in order to
* see if it exists.
*/
if(!Used)
LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName);
else
{
/* Did we receive or send a file? */
if(WriteAccess)
{
LONG Size;
/* Did the file remain empty? */
if(!(Size = GetFileSize(RealName)))
{
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_FILE_REMOVED_TXT),FilePart(RealName));
/* Delete empty file. */
if(DeleteFile(RealName))
LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_REMOVED_TXT),RealName);
else
LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName);
}
else
{
struct Node *SomeNode;
if(ByteMax)
{
if(Size >= ByteMax)
AddTransferInfo(FALSE,LocaleString(MSG_TERMXPR_FILE_RECEIVED_TXT),FilePart(RealName));
else
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_INCOMPLETE_FILE_RECEIVED_TXT),FilePart(RealName));
}
/* Try to identify the file type. */
switch(Config -> TransferConfig -> IdentifyFiles)
{
case IDENTIFY_IGNORE:
if(Config -> MiscConfig -> CreateIcons)
Identify(RealName,FALSE);
break;
case IDENTIFY_FILETYPE:
Identify(RealName,TRUE);
break;
case IDENTIFY_SOURCE:
IdentifySource(RealName,CurrentBBSName,&OpenDate);
if(Config -> MiscConfig -> CreateIcons)
Identify(RealName,FALSE);
break;
}
if(CPS_Minimum == (ULONG)~0)
CPS_Minimum = 0;
if(CPS_Count == 0)
{
CPS_Average = 0;
CPS_Count = 1;
}
LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_BYTES_TXT),RealName,Size,CPS_Minimum,CPS_Average / CPS_Count,CPS_Maximum);
if(SomeNode = CreateGenericListNode(0,RealName))
AddGenericListNode(GenericListTable[GLIST_DOWNLOAD],SomeNode,ADD_GLIST_BOTTOM);
}
}
else
{
/* Set the archived bit on files we uploaded? */
if(Config -> TransferConfig -> SetArchivedBit)
{
struct FileInfoBlock *FileInfo;
if(FileInfo = (struct FileInfoBlock *)AllocDosObject(DOS_FIB,TAG_DONE))
{
BPTR FileLock;
/* Get a lock on it. */
if(FileLock = Lock(RealName,ACCESS_READ))
{
/* Examine the file. */
if(Examine(FileLock,FileInfo))
{
/* Remove the lock. */
UnLock(FileLock);
/* Set the `archived' bit. */
SetProtection(RealName,FileInfo -> fib_Protection | FIBF_ARCHIVE);
}
else
UnLock(FileLock);
}
FreeDosObject(DOS_FIB,FileInfo);
}
}
AddTransferInfo(FALSE,LocaleString(MSG_TERMXPR_FILE_SENT_TXT),FilePart(RealName));
LogAction(LocaleString(MSG_TERMXPR_CLOSE_FILE_TXT),RealName);
RemoveUploadListItem(RealName);
}
}
}
CurrentFile = NULL;
return(1);
}
/* xpr_fread(APTR Buffer,LONG Size,LONG Count,struct Buffer *File):
*
* Read a few bytes from a file.
*/
LONG __saveds __asm
xpr_fread(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 LONG Count,register __a1 struct Buffer *File)
{
DB(kprintf("xpr_fread(0x%08lx,%ld,%ld,0x%08lx)\n",Buffer,Size,Count,File));
return(BufferRead(File,Buffer,Size * Count) / Size);
}
/* xpr_fwrite(APTR Buffer,LONG Size,LONG Count,struct Buffer *File):
*
* Write a few bytes to a file.
*/
LONG __saveds __asm
xpr_fwrite(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 LONG Count,register __a1 struct Buffer *File)
{
DB(kprintf("xpr_fwrite(0x%08lx,%ld,%ld,0x%08lx)\n",Buffer,Size,Count,File));
return(BufferWrite(File,Buffer,Size * Count) / Size);
}
/* xpr_fseek(struct Buffer *File,LONG Offset,LONG Origin):
*
* Move the read/write pointer in a file.
*/
LONG __saveds __asm
xpr_fseek(register __a0 struct Buffer *File,register __d0 LONG Offset,register __d1 LONG Origin)
{
DB(kprintf("xpr_fseek(0x%08lx,%ld,%ld)\n",File,Offset,Origin));
return(BufferSeek(File,Offset,Origin) ? 0 : -1);
}
/* xpr_sread(APTR Buffer,LONG Size,LONG Timeout):
*
* Read a few bytes from the serial port (including
* timeouts).
*/
LONG __saveds __asm
xpr_sread(register __a0 APTR Buffer,register __d0 LONG Size,register __d1 ULONG Timeout)
{
DB(kprintf("xpr_sread(0x%08lx,%ld,%ld)\n",Buffer,Size,Timeout));
/* No window available for output? */
if(!TransferWindow)
{
if(!OpenTransferWindow())
return(-1);
}
/* Are both IORequests available? */
if(WriteRequest && ReadRequest)
{
/* Valid size parameter? */
if(Size > 0)
{
ULONG Waiting;
UWORD Status;
GetSerialInfo(&Waiting,&Status);
/* Return error if carrier is lost. */
if(Config -> SerialConfig -> CheckCarrier && !Config -> SerialConfig -> DirectConnection)
{
if(Status & CIAF_COMCD)
{
if(!CarrierMessage)
{
CarrierMessage = TRUE;
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT));
}
ObtainSemaphore(&OnlineSemaphore);
if(Online)
{
WasOnline = Online;
Online = FALSE;
}
ReleaseSemaphore(&OnlineSemaphore);
TransferError = TRUE;
return(-1);
}
}
/* ALWAYS */
{
if(Waiting)
{
/* No timeout specified? Read as many
* bytes as available.
*/
if(!Timeout)
{
if(Waiting > Size)
Waiting = Size;
if(DoSerialRead(Buffer,Waiting))
{
if(SerialErrorReport(ReadRequest))
return(-1);
else
Waiting = ReadRequest -> IOSer . io_Actual;
}
BytesIn += Waiting;
return((LONG)Waiting);
}
/* Enough data pending to be read? */
if(Waiting >= Size)
{
if(DoSerialRead(Buffer,Size))
{
if(SerialErrorReport(ReadRequest))
return(-1);
else
Size = ReadRequest -> IOSer . io_Actual;
}
BytesIn += Size;
return(Size);
}
}
else
{
/* No timeout & no bytes available:
* return immediately.
*/
if(!Timeout)
return(0);
}
}
/* ALWAYS */
{
register ULONG SignalSet,
SerialMask = PORTMASK(ReadPort),
WindowMask = PORTMASK(TransferWindow -> UserPort);
/* Set up the timer. */
TimeRequest -> tr_node . io_Command = TR_ADDREQUEST;
TimeRequest -> tr_time . tv_secs = Timeout / MILLION;
TimeRequest -> tr_time . tv_micro = Timeout % MILLION;
/* Prevent early termination. */
ClrSignal(SerialMask | SIG_TIMER);
/* Start IO... */
SendIO(TimeRequest);
/* Set up the read request. */
StartSerialRead(Buffer,Size);
FOREVER
{
SignalSet = Wait(SerialMask | SIG_TIMER | WindowMask);
/* Abort file transfer? */
if(SignalSet & WindowMask)
{
LONG Result = CheckAbort(FALSE);
/* Let's get out of here
* and hope that the protocol
* will call xpr_chkabort()
* in time.
*/
if(Result)
{
if(TransferAbortState != Result)
TransferAbortState = Result;
/* Does the user want to cancel
* the transmission?
*/
if(Result < 0)
{
// Do it the hard way
if(TransferAbortCount++)
{
StopSerialRead();
if(!CheckIO(TimeRequest))
AbortIO(TimeRequest);
WaitIO(TimeRequest);
// Oh Janet, don't tell me to can it
DoSerialWrite(ZModemCancel,20);
return(Result);
}
}
/* Abort the read request. */
StopSerialRead();
/* Remove the timer request. */
if(!CheckIO(TimeRequest))
AbortIO(TimeRequest);
WaitIO(TimeRequest);
/* Did the driver receive any
* data?
*/
if(ReadRequest -> IOSer . io_Actual)
{
BytesIn += ReadRequest -> IOSer . io_Actual;
return((LONG)ReadRequest -> IOSer . io_Actual);
}
else
{
/* Take a second look and query the number of
* bytes ready to be received, there may
* still be some bytes in the buffer.
* Note: this depends on the way the
* driver handles read abort.
*/
Waiting = GetSerialWaiting();
/* Don't read too much. */
if(Size > Waiting)
Size = Waiting;
/* Are there any bytes to be transferred? */
if(Size)
{
/* Read the data. */
if(DoSerialRead(Buffer,Size))
{
if(SerialErrorReport(ReadRequest))
return(-1);
else
Size = ReadRequest -> IOSer . io_Actual;
}
BytesIn += Size;
}
return(Size);
}
}
}
/* Receive buffer filled? */
if(SignalSet & SerialMask)
{
/* Abort the timer request. */
if(!CheckIO(TimeRequest))
AbortIO(TimeRequest);
WaitIO(TimeRequest);
/* Did the request terminate gracefully? */
if(WaitSerialRead())
{
if(SerialErrorReport(ReadRequest))
return(-1);
else
Size = ReadRequest -> IOSer . io_Actual;
}
BytesIn += Size;
return(Size);
}
/* Hit by timeout? */
if(SignalSet & SIG_TIMER)
{
/* Abort the read request. */
StopSerialRead();
/* Remove the timer request. */
WaitIO(TimeRequest);
/* Did the driver receive any
* data?
*/
if(ReadRequest -> IOSer . io_Actual)
{
BytesIn += ReadRequest -> IOSer . io_Actual;
return((LONG)ReadRequest -> IOSer . io_Actual);
}
else
{
/* Take a second look and query the number of
* bytes ready to be received, there may
* still be some bytes in the buffer.
* Note: this depends on the way the
* driver handles read abort.
*/
Waiting = GetSerialWaiting();
/* Don't read too much. */
if(Size > Waiting)
Size = Waiting;
/* Are there any bytes to be transferred? */
if(Size)
{
/* Read the data. */
if(DoSerialRead(Buffer,Size))
{
if(SerialErrorReport(ReadRequest))
return(-1);
else
Size = ReadRequest -> IOSer . io_Actual;
}
BytesIn += Size;
}
return(Size);
}
}
}
}
}
else
return(0);
}
else
return(-1);
}
/* xpr_swrite(APTR Buffer,LONG Size):
*
* Write a few bytes to the serial port.
*/
LONG __saveds __asm
xpr_swrite(register __a0 APTR Buffer,register __d0 LONG Size)
{
DB(kprintf("xpr_swrite(0x%08lx,%ld)\n",Buffer,Size));
if(WriteRequest)
{
/* Return error if carrier is lost. */
if(Config -> SerialConfig -> CheckCarrier && !Config -> SerialConfig -> DirectConnection)
{
/* Is the carrier signal still present? */
if(GetSerialStatus() & CIAF_COMCD)
{
if(!CarrierMessage)
{
CarrierMessage = TRUE;
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT));
}
ObtainSemaphore(&OnlineSemaphore);
if(Online)
{
WasOnline = Online;
Online = FALSE;
}
ReleaseSemaphore(&OnlineSemaphore);
TransferError = TRUE;
return(-1);
}
}
/* Send the data. */
if(DoSerialWrite(Buffer,Size))
{
if(SerialErrorReport(WriteRequest))
return(-1);
}
else
BytesOut += Size;
return(0);
}
else
return(-1);
}
/* xpr_sflush():
*
* Release the contents of all serial buffers.
*/
LONG __saveds __asm
xpr_sflush()
{
DB(kprintf("xpr_sflush()\n"));
return((LONG)DoSerialCmd(CMD_CLEAR));
}
/* xpr_update(struct XPR_UPDATE *UpdateInfo):
*
* Update the information displayed in the transfer window.
*/
LONG __saveds __asm
xpr_update(register __a0 struct XPR_UPDATE *UpdateInfo)
{
DB(kprintf("xpr_update(0x%08lx)\n",UpdateInfo));
/* No window available for output? */
if(!TransferWindow)
{
if(!OpenTransferWindow())
return(0);
}
if(UpdateInfo)
{
BYTE NewByte = FALSE,
NewTime = FALSE;
if(TransferWindow -> Flags & WFLG_ZOOMED)
{
BOOLEAN Refresh;
if(!TransferZoomed)
{
ULONG Micros;
CurrentTime(&LastSeconds,&Micros);
Refresh = TRUE;
TransferZoomed = TRUE;
}
else
{
ULONG Seconds,Micros;
CurrentTime(&Seconds,&Micros);
if(Seconds > LastSeconds)
{
LastSeconds = Seconds;
Refresh = TRUE;
}
}
if(Refresh)
{
if(LastPercent > 0)
SPrintf(TransferTitleBuffer,"%s [%s %ld%%]",TransferWindowTitle,TruncateName(RealName),LastPercent);
else
SPrintf(TransferTitleBuffer,"%s [%s]",TransferWindowTitle,TruncateName(RealName));
SetWindowTitles(TransferWindow,TransferTitleBuffer,(STRPTR)-1);
}
}
else
{
if(TransferZoomed)
{
SetWindowTitles(TransferWindow,TransferWindowTitle,(STRPTR)-1);
TransferZoomed = FALSE;
}
}
if((UpdateInfo -> xpru_updatemask & XPRU_PROTOCOL) && UpdateInfo -> xpru_protocol)
LT_SetAttributes(TransferHandle,GAD_TRANSFER_PROTOCOL,GTTX_Text,UpdateInfo -> xpru_protocol,TAG_DONE);
if((UpdateInfo -> xpru_updatemask & XPRU_MSG) && UpdateInfo -> xpru_msg)
AddTransferInfo(FALSE,UpdateInfo -> xpru_msg);
if((UpdateInfo -> xpru_updatemask & XPRU_ERRORMSG) && UpdateInfo -> xpru_errormsg)
AddTransferInfo(TRUE,UpdateInfo -> xpru_errormsg);
if((UpdateInfo -> xpru_updatemask & XPRU_FILENAME) && UpdateInfo -> xpru_filename)
{
STRPTR FileName = UpdateInfo -> xpru_filename;
if(OriginalName[0])
{
if(!Stricmp(ShrunkenName,FileName))
FileName = OriginalName;
}
FileName = NewFileName(FileName,RealName);
LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,0,LABX_Text,TruncateName(FileName),TAG_DONE);
if(FileTransferInfo)
{
if(FileTransferInfo -> CurrentFile)
{
struct FileTransferNode *Node = (struct FileTransferNode *)FileTransferInfo -> CurrentFile -> Node . mln_Succ;
if(Node -> Node . mln_Succ)
LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,1,LABX_Text,TruncateName(Node -> Name),TAG_DONE);
else
LT_SetAttributes(TransferHandle,GAD_TRANSFER_FILE,LABX_Index,1,LABX_Text,LocaleString(MSG_GLOBAL_NONE_TXT),TAG_DONE);
}
PrintBox(GAD_TRANSFER_SIZE,2,ConvNumber,FileTransferInfo -> TotalSize);
if(FileTransferInfo -> TotalFiles)
PrintBox(GAD_TRANSFER_SIZE,4,LocaleString(MSG_TRANSFERPANEL_NUMBER_TO_GO_PERCENT_TXT),FileTransferInfo -> DoneFiles,FileTransferInfo -> TotalFiles,(100 * FileTransferInfo -> DoneFiles) / FileTransferInfo -> TotalFiles);
else
PrintBox(GAD_TRANSFER_SIZE,4,LocaleString(MSG_TRANSFERPANEL_NUMBER_TO_GO_PERCENT_TXT),FileTransferInfo -> DoneFiles,FileTransferInfo -> TotalFiles,0);
}
}
if((UpdateInfo -> xpru_updatemask & XPRU_FILESIZE) && UpdateInfo -> xpru_filesize != -1)
{
if(CurrentFile)
{
if(CurrentFile -> InfoPort)
PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber10,UpdateInfo -> xpru_filesize);
else
PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber,UpdateInfo -> xpru_filesize);
}
else
PrintBox(GAD_TRANSFER_SIZE,0,ConvNumber,UpdateInfo -> xpru_filesize);
if(ByteMax = UpdateInfo -> xpru_filesize)
NewByte = TRUE;
}
if((UpdateInfo -> xpru_updatemask & XPRU_BYTES) && UpdateInfo -> xpru_bytes != -1)
{
if(CurrentFile)
{
if(CurrentFile -> InfoPort)
PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber10,ByteVal = UpdateInfo -> xpru_bytes);
else
PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber,ByteVal = UpdateInfo -> xpru_bytes);
}
else
PrintBox(GAD_TRANSFER_SIZE,1,ConvNumber,ByteVal = UpdateInfo -> xpru_bytes);
if(FileTransferInfo)
{
ULONG Len = FileTransferInfo -> DoneSize + UpdateInfo -> xpru_bytes;
if(FileTransferInfo -> TotalSize)
PrintBox(GAD_TRANSFER_SIZE,3,LocaleString(MSG_TRANSFERPANEL_NUMBER_PERCENT_TXT),Len,(100 * Len) / FileTransferInfo -> TotalSize);
else
PrintBox(GAD_TRANSFER_SIZE,3,LocaleString(MSG_TRANSFERPANEL_NUMBER_PERCENT_TXT),Len,0);
}
if(ByteMax)
NewByte = TRUE;
if(CurrentFile)
{
if(CurrentFile -> InfoPort && !Uploading)
{
if(CurrentFile -> InfoData . id_NumBlocks && CurrentFile -> InfoData . id_BytesPerBlock)
{
if(ByteMax)
{
register LONG Space = CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed;
if(Space >= 0)
{
// Important! Only use the number of bytes still
// to be transferred.
register LONG Blocks = CalculateBlocks(ByteMax - ByteVal,CurrentFile -> InfoData . id_BytesPerBlock);
// Did we take a look at the filing system yet?
if(!TypeChecked)
{
// If this is not a block mapped device
// we cannot guess what will happen if
// it fills up (and whether it fills up at all).
if(!IsBlockMappedDevice(CurrentFile -> InfoPort))
DontWorry = TRUE;
// Ok, done
TypeChecked = TRUE;
}
if(Space >= Blocks || DontWorry)
PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),Space * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks,"");
else
{
if(!Alerted)
{
Alerted = TRUE;
Say(LocaleString(MSG_TERMXPR_SAY_FILE_MAY_NOT_FIT_TXT));
}
PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),Space * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks,LocaleString(MSG_TERMXPR_FILE_MAY_NOT_FIT_TXT));
}
}
else
PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),(CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed) * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks);
}
else
PrintBox(GAD_TRANSFER_FILE,2,LocaleString(MSG_TERMXPR_BYTES_FULL_TXT),(CurrentFile -> InfoData . id_NumBlocks - CurrentFile -> InfoData . id_NumBlocksUsed) * CurrentFile -> InfoData . id_BytesPerBlock,100 * (CurrentFile -> InfoData . id_NumBlocksUsed) / CurrentFile -> InfoData . id_NumBlocks);
}
}
}
}
if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKS) && UpdateInfo -> xpru_blocks != -1)
PrintBox(GAD_TRANSFER_SIZE,5,ConvNumber,UpdateInfo -> xpru_blocks);
if((UpdateInfo -> xpru_updatemask & XPRU_DATARATE) && UpdateInfo -> xpru_datarate > 0)
{
register LONG Change;
CPS_Current = UpdateInfo -> xpru_datarate;
if(CPS_Last)
{
if(CPS_Last < UpdateInfo -> xpru_datarate)
Change = (100 * (UpdateInfo -> xpru_datarate - CPS_Last)) / CPS_Last;
else
Change = (100 * (CPS_Last - UpdateInfo -> xpru_datarate)) / CPS_Last;
}
else
Change = 100;
if(Change > 1)
{
PrintBox(GAD_TRANSFER_SECONDS,0,ConvNumber,UpdateInfo -> xpru_datarate);
CPS_Last = UpdateInfo -> xpru_datarate;
}
if(UpdateInfo -> xpru_datarate < CPS_Minimum)
CPS_Minimum = UpdateInfo -> xpru_datarate;
if(UpdateInfo -> xpru_datarate > CPS_Maximum)
CPS_Maximum = UpdateInfo -> xpru_datarate;
if((ULONG)(CPS_Average + UpdateInfo -> xpru_datarate) >= CPS_Average)
{
CPS_Average += UpdateInfo -> xpru_datarate;
CPS_Count++;
}
}
if((UpdateInfo -> xpru_updatemask & XPRU_CHARDELAY) && UpdateInfo -> xpru_chardelay != -1)
PrintBox(GAD_TRANSFER_SECONDS,1,ConvNumber,UpdateInfo -> xpru_chardelay);
if((UpdateInfo -> xpru_updatemask & XPRU_PACKETDELAY) && UpdateInfo -> xpru_packetdelay != -1)
PrintBox(GAD_TRANSFER_SECONDS,2,ConvNumber,UpdateInfo -> xpru_packetdelay);
if((UpdateInfo -> xpru_updatemask & XPRU_PACKETTYPE) && UpdateInfo -> xpru_packettype != -1)
{
if(UpdateInfo -> xpru_packettype > 32 && UpdateInfo -> xpru_packettype < 256)
{
if(IsPrintable[UpdateInfo -> xpru_packettype])
PrintBox(GAD_TRANSFER_SECONDS,3,"`%lc'",UpdateInfo -> xpru_packettype);
else
PrintBox(GAD_TRANSFER_SECONDS,3,ConvNumber,UpdateInfo -> xpru_packettype);
}
else
PrintBox(GAD_TRANSFER_SECONDS,3,ConvNumber,UpdateInfo -> xpru_packettype);
}
if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKCHECK) && UpdateInfo -> xpru_blockcheck)
PrintBox(GAD_TRANSFER_SECONDS,4,UpdateInfo -> xpru_blockcheck);
if((UpdateInfo -> xpru_updatemask & XPRU_BLOCKSIZE) && UpdateInfo -> xpru_blocksize != -1)
PrintBox(GAD_TRANSFER_SECONDS,5,ConvNumber,UpdateInfo -> xpru_blocksize);
if((UpdateInfo -> xpru_updatemask & XPRU_EXPECTTIME) && UpdateInfo -> xpru_expecttime)
{
PrintBox(GAD_TRANSFER_TOTALTIME,0,UpdateInfo -> xpru_expecttime);
if(TimeMax = GetSeconds((STRPTR)UpdateInfo -> xpru_expecttime))
NewTime = TRUE;
}
if((UpdateInfo -> xpru_updatemask & XPRU_ELAPSEDTIME) && UpdateInfo -> xpru_elapsedtime)
{
PrintBox(GAD_TRANSFER_TOTALTIME,1,UpdateInfo -> xpru_elapsedtime);
TimeVal = GetSeconds((STRPTR)UpdateInfo -> xpru_elapsedtime);
if(TimeMax)
NewTime = TRUE;
}
if((UpdateInfo -> xpru_updatemask & XPRU_ERRORS) && UpdateInfo -> xpru_errors != -1)
{
PrintBox(GAD_TRANSFER_ERRORS,0,ConvNumber,UpdateInfo -> xpru_errors);
if(!ErrorNotified && Config -> TransferConfig -> ErrorNotification && UpdateInfo -> xpru_errors >= Config -> TransferConfig -> ErrorNotification)
{
ErrorNotified = TRUE;
WakeUp(TransferWindow,SOUND_ERROR);
}
}
if((UpdateInfo -> xpru_updatemask & XPRU_TIMEOUTS) && UpdateInfo -> xpru_timeouts != -1)
PrintBox(GAD_TRANSFER_ERRORS,1,ConvNumber,UpdateInfo -> xpru_timeouts);
if(NewByte)
{
LONG Percent;
if(ByteMax)
Percent = (100 * ByteVal) / ByteMax;
else
Percent = 0;
if(Percent != LastPercent)
{
UBYTE LocalBuffer[10];
SPrintf(LocalBuffer,"%ld%%",Percent);
LastPercent = Percent;
LT_SetAttributes(TransferHandle,GAD_TRANSFER_PERCENT,
LAGA_Percent, Percent,
LAGA_InfoText, LocalBuffer,
TAG_DONE);
}
}
if(NewTime)
{
register LONG TimeDif,Change;
if(TimeVal > TimeMax)
TimeDif = 0;
else
TimeDif = TimeMax - TimeVal;
if(LastTimeDif)
{
if(LastTimeDif < TimeDif)
Change = (100 * (TimeDif - LastTimeDif)) / LastTimeDif;
else
Change = (100 * (LastTimeDif - TimeDif)) / LastTimeDif;
}
else
Change = 100;
/* Don't update the display unless the change
* exceeds 2% of the previous value.
*/
if(Change > 2)
{
UBYTE LocalBuffer[10];
LONG Percent;
LastTimeDif = TimeDif;
if(TimeMax)
Percent = (100 * TimeDif) / TimeMax;
else
Percent = 0;
SPrintf(LocalBuffer,"%2ld:%02ld:%02ld",TimeDif / 3600,(TimeDif / 60) % 60,TimeDif % 60);
LT_SetAttributes(TransferHandle,GAD_TRANSFER_TIME,
LAGA_Percent, Percent,
LAGA_InfoText, LocalBuffer,
TAG_DONE);
/* A rapidly changing transfer time display would
* cause the transfer completion time display to
* change at the same pace. As the completion time
* display calculation is rather costly, a change smaller
* than 5% of the previous value is silently ignored.
*/
if(Change > 5)
{
UBYTE DateTimeBuffer[256];
struct DateStamp Stamp;
/* Obtain current time. */
DateStamp(&Stamp);
/* Add the time to go. */
Stamp . ds_Tick += (TimeDif % 60) * TICKS_PER_SECOND;
Stamp . ds_Minute += TimeDif / 60 + Stamp . ds_Tick / (60 * TICKS_PER_SECOND);
Stamp . ds_Days += Stamp . ds_Minute / 1440;
Stamp . ds_Tick %= 60 * TICKS_PER_SECOND;
Stamp . ds_Minute %= 1440;
/* Conversion succeeded? */
if(FormatStamp(&Stamp,NULL,NULL,DateTimeBuffer,TRUE))
PrintBox(GAD_TRANSFER_FILE,3,DateTimeBuffer);
}
}
}
}
if(TransferPerfWindow)
{
struct RastPort *RPort = TransferPerfWindow -> RPort;
LONG Height,Left,Top,Min,Avg,Cur;
Left = TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1);
Height = TransferPerfWindow -> Height - (TransferPerfWindow -> BorderTop + TransferPerfWindow -> BorderBottom + 1);
Top = TransferPerfWindow -> BorderTop + Height;
if(CPS_Maximum && CPS_Maximum != ~0)
{
Min = (Height * CPS_Minimum) / CPS_Maximum;
Cur = (Height * CPS_Current) / CPS_Maximum;
if(CPS_Count)
Avg = ((CPS_Average / CPS_Count) * Height) / CPS_Maximum;
else
Avg = 0;
}
else
Min = Avg = Cur = 0;
if(CPL_Min == -1)
CPL_Min = Min;
if(CPL_Avg == -1)
CPL_Avg = Avg;
if(CPL_Cur == -1)
CPL_Cur = Cur;
ScrollRaster(RPort,1,0,TransferPerfWindow -> BorderLeft,TransferPerfWindow -> BorderTop,TransferPerfWindow -> Width - (TransferPerfWindow -> BorderRight + 1),TransferPerfWindow -> Height - (TransferPerfWindow -> BorderBottom + 1));
if(CPL_Cur != -1 && Cur != -1)
{
SetAPen(RPort,DrawInfo -> dri_Pens[SHADOWPEN]);
Move(RPort,Left,Top - CPL_Cur);
Draw(RPort,Left,Top - Cur);
}
if(CPL_Min != -1 && Min != -1)
{
SetAPen(RPort,DrawInfo -> dri_Pens[HIGHLIGHTTEXTPEN]);
Move(RPort,Left,Top - CPL_Min);
Draw(RPort,Left,Top - Min);
}
if(CPL_Avg != -1 && Avg != -1)
{
SetAPen(RPort,DrawInfo -> dri_Pens[FILLPEN]);
Move(RPort,Left,Top - CPL_Avg);
Draw(RPort,Left,Top - Avg);
}
CPL_Min = Min;
CPL_Avg = Avg;
CPL_Cur = Cur;
}
return(1);
}
/* xpr_chkabort():
*
* Check if the user has aborted the transfer.
*/
LONG __saveds __asm
xpr_chkabort()
{
LONG Result;
DB(kprintf("xpr_chkabort()\n"));
if(TransferAbortState != 0)
{
Result = TransferAbortState;
TransferAbortState = 0;
}
else
Result = CheckAbort(Config -> SerialConfig -> CheckCarrier && !Config -> SerialConfig -> DirectConnection);
return(Result);
}
/* xpr_gets(STRPTR Prompt,STRPTR Buffer):
*
* Prompt the user for string input.
*/
LONG __saveds __asm
xpr_gets(register __a0 STRPTR Prompt,register __a1 STRPTR Buffer)
{
enum { GAD_OK=1,GAD_CANCEL,GAD_STRING };
struct LayoutHandle *Handle;
LONG Success = FALSE;
UBYTE LocalBuffer[256];
DB(kprintf("xpr_gets(\"%s\",\"%s\")\n",Prompt,Buffer));
if(strlen(Buffer) > 255)
{
CopyMem(Buffer,LocalBuffer,255);
LocalBuffer[255] = 0;
}
else
strcpy(LocalBuffer,Buffer);
if(!Prompt)
Prompt = LocaleString(MSG_TERMXPR_INPUT_REQUIRED_TXT);
if(Handle = LT_CreateHandleTags(Window -> WScreen,
LH_LocaleHook, &LocaleHook,
TAG_DONE))
{
struct Window *PanelWindow;
LT_New(Handle,
LA_Type, VERTICAL_KIND,
TAG_DONE);
{
LT_New(Handle,
LA_Type, VERTICAL_KIND,
LA_LabelText, Prompt,
TAG_DONE);
{
LT_New(Handle,
LA_Type, STRING_KIND,
LA_STRPTR, LocalBuffer,
LA_ID, GAD_STRING,
LA_Chars, 30,
TAG_DONE);
LT_EndGroup(Handle);
}
LT_New(Handle,
LA_Type,VERTICAL_KIND,
TAG_DONE);
{
LT_New(Handle,
LA_Type, XBAR_KIND,
LAXB_FullSize, TRUE,
TAG_DONE);
LT_EndGroup(Handle);
}
LT_New(Handle,LA_Type,HORIZONTAL_KIND,
LAGR_SameSize, TRUE,
LAGR_Spread, TRUE,
TAG_DONE);
{
LT_New(Handle,
LA_Type, BUTTON_KIND,
LA_LabelID, MSG_TERMXPR_OKAY_GAD,
LA_ID, GAD_OK,
LABT_ReturnKey, TRUE,
LABT_ExtraFat, TRUE,
TAG_DONE);
LT_New(Handle,
LA_Type, BUTTON_KIND,
LA_LabelID, MSG_GLOBAL_CANCEL_GAD,
LA_ID, GAD_CANCEL,
LABT_EscKey, TRUE,
LABT_ExtraFat, TRUE,
TAG_DONE);
LT_EndGroup(Handle);
}
}
if(PanelWindow = LT_Layout(Handle,LocaleString(MSG_GLOBAL_ENTER_TEXT_TXT),NULL,0,0,IDCMP_CLOSEWINDOW,0,
LAWN_HelpHook, &GuideHook,
LAWN_Parent, Window,
WA_DepthGadget, TRUE,
WA_CloseGadget, TRUE,
WA_DragBar, TRUE,
WA_RMBTrap, TRUE,
WA_Activate, TRUE,
TAG_DONE))
{
struct IntuiMessage *Message;
BOOLEAN Done = FALSE;
ULONG MsgClass,
MsgQualifier;
UWORD MsgCode;
struct Gadget *MsgGadget;
PushWindow(PanelWindow);
LT_ShowWindow(Handle,TRUE);
LT_Activate(Handle,GAD_STRING);
do
{
if(Wait(PORTMASK(PanelWindow -> UserPort) | SIG_BREAK) & SIG_BREAK)
break;
while(Message = (struct IntuiMessage *)GT_GetIMsg(PanelWindow -> UserPort))
{
MsgClass = Message -> Class;
MsgQualifier = Message -> Qualifier;
MsgCode = Message -> Code;
MsgGadget = (struct Gadget *)Message -> IAddress;
GT_ReplyIMsg(Message);
LT_HandleInput(Handle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget);
if(MsgClass == IDCMP_CLOSEWINDOW)
Done = TRUE;
if(MsgClass == IDCMP_GADGETUP)
{
switch(MsgGadget -> GadgetID)
{
case GAD_STRING:
if(MsgCode == '\r')
{
if(strcmp(Buffer,LocalBuffer))
NewOptions = TRUE;
strcpy(Buffer,LocalBuffer);
Success = Done = TRUE;
LT_PressButton(Handle,GAD_OK);
}
break;
case GAD_OK:
LT_UpdateStrings(Handle);
if(strcmp(Buffer,LocalBuffer))
NewOptions = TRUE;
strcpy(Buffer,LocalBuffer);
Success = Done = TRUE;
break;
case GAD_CANCEL:
Done = TRUE;
break;
}
}
}
}
while(!Done);
PopWindow();
}
LT_DeleteHandle(Handle);
}
return(Success);
}
/* xpr_setserial(LONG Status):
*
* Set/read the serial status (parameters).
*/
LONG __saveds __asm
xpr_setserial(register __d0 LONG Status)
{
DB(kprintf("xpr_setserial(0x%08lx)\n",Status));
if(WriteRequest)
{
STATIC LONG XprBauds[12] =
{
110,
300,
1200,
2400,
4800,
9600,
19200,
31250,
38400,
57600,
76800,
115200
};
LONG Return,i;
StopSerialRead();
StopSerialWrite();
DoSerialCmd(SDCMD_QUERY);
Return = WriteRequest -> io_SerFlags & 0xFF;
if(WriteRequest -> io_ExtFlags & SEXTF_MSPON)
Return |= ST_PARTYMARKON;
if(WriteRequest -> io_ExtFlags & SEXTF_MARK)
Return |= ST_PARTYMARK;
if(WriteRequest -> io_StopBits == 2)
Return |= ST_2BITS;
if(WriteRequest -> io_ReadLen == 7)
Return |= ST_READ7;
if(WriteRequest -> io_WriteLen == 7)
Return |= ST_WRITE7;
for(i = 0 ; i < 12 ; i++)
{
if(XprBauds[i] >= WriteRequest -> io_Baud)
{
Return |= (i << 16);
break;
}
}
/* Update serial parameters, don't change
* the baud rate however.
*/
if(Status != -1)
{
WriteRequest -> io_SerFlags = Status & 0xFF;
WriteRequest -> io_ExtFlags = 0;
if(Status & ST_PARTYMARKON)
WriteRequest -> io_ExtFlags |= SEXTF_MSPON;
if(Status & ST_PARTYMARK)
WriteRequest -> io_ExtFlags |= SEXTF_MARK;
if(Status & ST_2BITS)
WriteRequest -> io_StopBits = 2;
else
WriteRequest -> io_StopBits = 1;
if(Status & ST_READ7)
WriteRequest -> io_ReadLen = 7;
else
WriteRequest -> io_ReadLen = 8;
if(Status & ST_WRITE7)
WriteRequest -> io_WriteLen = 7;
else
WriteRequest -> io_WriteLen = 8;
WriteRequest -> IOSer . io_Command = SDCMD_SETPARAMS;
DoIO(WriteRequest);
CopyMem(WriteRequest,ReadRequest,sizeof(struct IOExtSer));
ReadRequest -> IOSer . io_Message . mn_ReplyPort = ReadPort;
CopyWriteFlags();
if(WriteRequest -> io_SerFlags & SERF_7WIRE)
{
if(Config -> SerialConfig -> HandshakingProtocol == HANDSHAKING_NONE)
Config -> SerialConfig -> HandshakingProtocol = HANDSHAKING_RTSCTS_DSR;
}
else
{
if(Config -> SerialConfig -> HandshakingProtocol != HANDSHAKING_NONE)
Config -> SerialConfig -> HandshakingProtocol = HANDSHAKING_NONE;
}
}
return(Return);
}
else
return(-1);
}
/* xpr_ffirst(STRPTR Buffer,STRPTR Pattern):
*
* Batch file upload: find the first matching file and return
* its name.
*/
LONG __saveds __asm
xpr_ffirst(register __a0 STRPTR Buffer,register __a1 STRPTR Pattern)
{
DB(kprintf("xpr_ffirst(0x%08lx,\"%s\")\n",Buffer,Pattern));
if(FileTransferInfo)
{
FileTransferInfo -> DoneSize = 0;
FileTransferInfo -> DoneFiles = 0;
FileTransferInfo -> CurrentFile = (struct FileTransferNode *)FileTransferInfo -> FileList . mlh_Head;
FileTransferInfo -> CurrentSize = FileTransferInfo -> CurrentFile -> Size;
if(Config -> TransferConfig -> MangleFileNames)
{
UBYTE LocalName[MAX_FILENAME_LENGTH],*Char;
strcpy(OriginalName,FileTransferInfo -> CurrentFile -> Name);
ShrinkName(FilePart(FileTransferInfo -> CurrentFile -> Name),LocalName,12,TRUE);
strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name);
Char = PathPart(Buffer);
*Char = 0;
AddPart(Buffer,LocalName,MAX_FILENAME_LENGTH);
strcpy(ShrunkenName,Buffer);
}
else
{
OriginalName[0] = 0;
strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name);
}
return(1);
}
else
return(0);
}
/* xpr_fnext(LONG OldState,STRPTR Buffer,STRPTR Pattern):
*
* Batch file upload: find the next matching file
* - if any - and return its name.
*/
LONG __saveds __asm
xpr_fnext(register __d0 LONG OldState,register __a0 STRPTR Buffer,register __a1 STRPTR Pattern)
{
DB(kprintf("xpr_fnext(%ld,0x%08lx,\"%s\")\n",OldState,Buffer,Pattern));
if(FileTransferInfo)
{
if(FileTransferInfo -> CurrentFile -> Node . mln_Succ -> mln_Succ)
{
FileTransferInfo -> DoneSize += FileTransferInfo -> CurrentSize;
FileTransferInfo -> DoneFiles += 1;
FileTransferInfo -> CurrentFile = (struct FileTransferNode *)FileTransferInfo -> CurrentFile -> Node . mln_Succ;
FileTransferInfo -> CurrentSize = FileTransferInfo -> CurrentFile -> Size;
if(Config -> TransferConfig -> MangleFileNames)
{
UBYTE LocalName[MAX_FILENAME_LENGTH],*Char;
strcpy(OriginalName,FileTransferInfo -> CurrentFile -> Name);
ShrinkName(FilePart(FileTransferInfo -> CurrentFile -> Name),LocalName,12,TRUE);
strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name);
Char = PathPart(Buffer);
*Char = 0;
AddPart(Buffer,LocalName,MAX_FILENAME_LENGTH);
strcpy(ShrunkenName,Buffer);
}
else
{
OriginalName[0] = 0;
strcpy(Buffer,FileTransferInfo -> CurrentFile -> Name);
}
return(1);
}
}
return(0);
}
/* xpr_finfo(STRPTR FileName,LONG InfoType):
*
* Return information on a given file.
*/
LONG __saveds __asm
xpr_finfo(register __a0 STRPTR FileName,register __d0 LONG InfoType)
{
struct FileInfoBlock *FileInfo;
LONG Size;
DB(kprintf("xpr_finfo(\"%s\",%ld)\n",FileName,InfoType));
switch(InfoType)
{
/* Return the file size. */
case 1: Size = 0;
if(FileInfo = (struct FileInfoBlock *)AllocDosObject(DOS_FIB,TAG_DONE))
{
UBYTE RealName[MAX_FILENAME_LENGTH];
BPTR FileLock;
if(OriginalName[0])
{
if(!Stricmp(ShrunkenName,FileName))
FileName = NewFileName(OriginalName,RealName);
else
FileName = NewFileName(FileName,RealName);
}
else
FileName = NewFileName(FileName,RealName);
if(FileLock = Lock(FileName,ACCESS_READ))
{
if(Examine(FileLock,FileInfo))
{
if(FileInfo -> fib_DirEntryType < 0)
Size = FileInfo -> fib_Size;
}
UnLock(FileLock);
}
FreeDosObject(DOS_FIB,FileInfo);
}
return(Size);
/* Return the file transfer mode. */
case 2: return(BinaryTransfer ? 1 : 2);
/* Ignore the rest. */
default:return(0);
}
}
/* xpr_options(LONG NumOpts,struct xpr_option **Opts):
*
* Provide a more polished user interface to set the
* transfer protocol options.
*/
ULONG __saveds __asm
xpr_options(register __d0 LONG NumOpts,register __a0 struct xpr_option **Opts)
{
DB(kprintf("xpr_options(%ld,0x%08lx)\n",NumOpts,Opts));
if(NumOpts && Opts)
{
enum { GAD_USE=1,GAD_CANCEL,GAD_SPECIAL };
struct LayoutHandle *Handle;
ULONG Flags = NULL;
/* We only have 32 bits! */
if(NumOpts > 32)
NumOpts = 32;
if(Handle = LT_CreateHandleTags(Window -> WScreen,
LH_LocaleHook, &LocaleHook,
TAG_DONE))
{
struct Window *PanelWindow;
LONG i,Split;
if(NumOpts > 16)
Split = NumOpts / 2;
else
Split = -1;
LT_New(Handle,
LA_Type, VERTICAL_KIND,
TAG_DONE);
{
LT_New(Handle,
LA_Type, HORIZONTAL_KIND,
LA_LabelID, MSG_V36_1501,
TAG_DONE);
{
LT_New(Handle,
LA_Type, VERTICAL_KIND,
TAG_DONE);
{
for(i = 0 ; i < NumOpts ; i++)
{
if(Opts[i])
{
switch(Opts[i] -> xpro_type)
{
case XPRO_BOOLEAN:
LT_New(Handle,
LA_Type, CHECKBOX_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_ID, GAD_SPECIAL + i,
GTCB_Checked, GetOptionMode(Opts[i]),
TAG_DONE);
break;
case XPRO_LONG:
LT_New(Handle,
LA_Type, INTEGER_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_ID, GAD_SPECIAL + i,
LA_Chars, 15,
GTIN_Number, Atol(Opts[i] -> xpro_value),
LAIN_UseIncrementers, TRUE,
TAG_DONE);
break;
case XPRO_STRING:
LT_New(Handle,
LA_Type, STRING_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_ID, GAD_SPECIAL + i,
LA_Chars, 15,
GTST_String, Opts[i] -> xpro_value,
GTST_MaxChars, Opts[i] -> xpro_length - 1,
TAG_DONE);
break;
case XPRO_COMMPAR:
LT_New(Handle,
LA_Type, STRING_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_ID, GAD_SPECIAL + i,
LA_Chars, 15,
LA_HighLabel, TRUE,
GTST_String, Opts[i] -> xpro_value,
GTST_MaxChars, Opts[i] -> xpro_length - 1,
TAG_DONE);
break;
case XPRO_HEADER:
LT_New(Handle,
LA_Type, TEXT_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_HighLabel, TRUE,
GTTX_Text, " ",
TAG_DONE);
break;
case XPRO_COMMAND:
LT_New(Handle,
LA_Type, BUTTON_KIND,
LA_LabelText, Opts[i] -> xpro_description,
LA_ID, GAD_SPECIAL + i,
LA_Chars, 15,
TAG_DONE);
break;
}
}
if(i == Split)
{
LT_EndGroup(Handle);
LT_New(Handle,
LA_Type, VERTICAL_KIND,
TAG_DONE);
}
}
LT_EndGroup(Handle);
}
LT_EndGroup(Handle);
}
LT_New(Handle,
LA_Type,VERTICAL_KIND,
TAG_DONE);
{
LT_New(Handle,
LA_Type, XBAR_KIND,
LAXB_FullSize, TRUE,
TAG_DONE);
LT_EndGroup(Handle);
}
LT_New(Handle,LA_Type,HORIZONTAL_KIND,
LAGR_SameSize, TRUE,
LAGR_Spread, TRUE,
TAG_DONE);
{
LT_New(Handle,
LA_Type, BUTTON_KIND,
LA_LabelID, MSG_GLOBAL_USE_GAD,
LA_ID, GAD_USE,
LABT_ReturnKey, TRUE,
LABT_ExtraFat, TRUE,
TAG_DONE);
LT_New(Handle,
LA_Type, BUTTON_KIND,
LA_LabelID, MSG_GLOBAL_CANCEL_GAD,
LA_ID, GAD_CANCEL,
LABT_EscKey, TRUE,
LABT_ExtraFat, TRUE,
TAG_DONE);
LT_EndGroup(Handle);
}
LT_EndGroup(Handle);
}
if(PanelWindow = LT_Layout(Handle,OptionTitle ? OptionTitle : LocaleString(MSG_TERMXPR_TRANSFER_OPTIONS_TXT),NULL,0,0,IDCMP_CLOSEWINDOW,0,
LAWN_HelpHook, &GuideHook,
LAWN_Parent, Window,
WA_DepthGadget, TRUE,
WA_CloseGadget, TRUE,
WA_DragBar, TRUE,
WA_RMBTrap, TRUE,
WA_Activate, TRUE,
TAG_DONE))
{
struct IntuiMessage *Message;
BOOLEAN Done = FALSE;
ULONG MsgClass,
MsgQualifier;
UWORD MsgCode;
struct Gadget *MsgGadget;
BOOLEAN CheckFlags = FALSE;
PushWindow(PanelWindow);
LT_ShowWindow(Handle,TRUE);
do
{
if(Wait(PORTMASK(PanelWindow -> UserPort) | SIG_BREAK) & SIG_BREAK)
break;
while(Message = (struct IntuiMessage *)GT_GetIMsg(PanelWindow -> UserPort))
{
MsgClass = Message -> Class;
MsgQualifier = Message -> Qualifier;
MsgCode = Message -> Code;
MsgGadget = (struct Gadget *)Message -> IAddress;
GT_ReplyIMsg(Message);
LT_HandleInput(Handle,MsgQualifier,&MsgClass,&MsgCode,&MsgGadget);
if(MsgClass == IDCMP_CLOSEWINDOW)
Done = TRUE;
if(MsgClass == IDCMP_GADGETUP)
{
switch(MsgGadget -> GadgetID)
{
case GAD_USE:
Done = CheckFlags = TRUE;
break;
case GAD_CANCEL:
Done = TRUE;
break;
default:
if(MsgGadget -> GadgetID - GAD_SPECIAL < NumOpts)
{
i = MsgGadget -> GadgetID - GAD_SPECIAL;
if(Opts[i] -> xpro_type == XPRO_COMMAND || (Opts[i] -> xpro_type == XPRO_COMMPAR && MsgCode != '\t'))
{
Flags = (1L << i);
XPRCommandSelected = Done = CheckFlags = TRUE;
}
}
break;
}
}
}
}
while(!Done);
PopWindow();
if(CheckFlags)
{
LT_LockWindow(PanelWindow);
for(i = 0 ; i < NumOpts ; i++)
{
if(Opts[i])
{
switch(Opts[i] -> xpro_type)
{
case XPRO_BOOLEAN:
if(LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE) != GetOptionMode(Opts[i]))
{
Flags |= (1L << i);
if(LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE))
strcpy(Opts[i] -> xpro_value,"yes");
else
strcpy(Opts[i] -> xpro_value,"no");
NewOptions = TRUE;
}
break;
case XPRO_LONG:
if(Atol(Opts[i] -> xpro_value) != LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE))
{
Flags |= (1L << i);
SPrintf(Opts[i] -> xpro_value,"%ld",LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE));
NewOptions = TRUE;
}
break;
case XPRO_STRING:
if(strcmp(Opts[i] -> xpro_value,(STRPTR)LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE)))
{
Flags |= (1L << i);
strcpy(Opts[i] -> xpro_value,(STRPTR)LT_GetAttributes(Handle,GAD_SPECIAL + i,TAG_DONE));
NewOptions = TRUE;
}
break;
}
}
}
LT_UnlockWindow(PanelWindow);
}
else
Flags = NULL;
}
LT_DeleteHandle(Handle);
}
return(Flags);
}
else
return(NULL);
}
/* xpr_unlink(STRPTR FileName):
*
* Remove (delete) a given file.
*/
LONG __saveds __asm
xpr_unlink(register __a0 STRPTR FileName)
{
DB(kprintf("xpr_unlink(\"%s\")\n",FileName));
/* Sorry, but it is far too dangerous to let the protocol
* remove any files with path name substitution enabled.
* The protocol could accidentally hit the wrong file.
*/
if(!Config -> TransferConfig -> OverridePath)
{
if(OriginalName[0])
{
if(!Stricmp(ShrunkenName,FileName))
FileName = OriginalName;
}
if(DeleteFile(FileName))
{
LogAction(LocaleString(MSG_TERMXPR_LOGMSG_DELETE_FILE_TXT),FilePart(FileName));
return(0);
}
}
return(-1);
}
/* xpr_squery():
*
* Check how many characters are present in the serial buffer.
*/
LONG __saveds __asm
xpr_squery()
{
DB(kprintf("xpr_squery()\n"));
if(WriteRequest)
{
ULONG Waiting;
UWORD Status;
GetSerialInfo(&Waiting,&Status);
/* Return error if carrier is lost. */
if((Status & CIAF_COMCD) && Config -> SerialConfig -> CheckCarrier && !Config -> SerialConfig -> DirectConnection)
{
if(!CarrierMessage)
{
CarrierMessage = TRUE;
AddTransferInfo(TRUE,LocaleString(MSG_TERMXPR_CARRIER_LOST_TXT));
}
ObtainSemaphore(&OnlineSemaphore);
if(Online)
{
WasOnline = Online;
Online = FALSE;
}
ReleaseSemaphore(&OnlineSemaphore);
TransferError = TRUE;
}
else
return((LONG)Waiting);
}
return(-1);
}
/* xpr_getptr(LONG InfoType):
*
* Return a pointer to the term custom screen.
*/
LONG __saveds __asm
xpr_getptr(register __d0 LONG InfoType)
{
DB(kprintf("xpr_getptr(%ld)\n",InfoType));
if(InfoType == 1)
return((LONG)Window -> WScreen);
else
return(-1);
}
/* xpr_stealopts(STRPTR Prompt,STRPTR Buffer):
*
* Steal the contents of the options buffer (replacement
* for xpr_gets).
*/
LONG __saveds __asm
xpr_stealopts(register __a0 STRPTR Prompt,register __a1 STRPTR Buffer)
{
DB(kprintf("xpr_stealopts(\"%s\",\"%s\")\n",Prompt,Buffer));
if(Buffer)
strcpy(ProtocolOptsBuffer,Buffer);
return(1);
}